package read.niit.common

import org.apache.spark.streaming.dstream.DStream
import read.niit.bean.Reader

trait TController {

  def dispatch(reader:DStream[Reader]):Unit

}
